package vip.zhenzicheng.nettyadv.server.asyncpro;

import vip.zhenzicheng.nettyadv.vo.MyMessage;

import java.util.logging.Logger;

/**
 * 消息转任务处理器的缺省实现
 *
 * @author zhenzicheng
 * @date 2022-06-14 10:06
 */
public class DefaultTaskProcessor implements ITaskProcessor {

  private static final Logger LOG = Logger.getLogger(DefaultTaskProcessor.class.getSimpleName());

  @Override
  public Runnable execAsyncTask(MyMessage msg) {
    return () -> LOG.info("DefaultTaskProcessor模拟任务处理：" + msg.getBody());
  }
}
